from pprint import pprint

from tasks import add, app,dump_context

#该方法实际上是另一个方法的星号快捷方式 add.apply_async((2, 2))
res = add.delay(2, 2)
dump_context.delay(2, 2)
# 该ready()方法返回任务是否已完成处理：
pprint(res.ready())
pprint(res.state)
# 您可以等待结果完成，但这很少使用，因为它将异步调用转换为同步调用：
# 如果任务引发异常，您还可以访问原始回溯：result.traceback
pprint(res.get(timeout=1,propagate=False))

pprint(res.state)
res = app.AsyncResult('this-id-does-not-exist')
print(res.state)
res = app.AsyncResult('this-id-does-not-exist')
print(res.state)

add.signature((2, 2), countdown=10)
add.s(2, 2)